15e3d31a4e6a86f20fa3ff211fc1eadcbecec17e,src/test/java/com/lambdaworks/redis/pubsub/PubSubRxTest.java,PubSubRxTest,pubsubChannels,#,197
Before Change
@Test
public void pubsubChannels() throws Exception {
pubsub.subscribe(channel).toBlocking().singleOrDefault(null);
List<String> result = pubsub2.pubsubChannels().toList().toBlocking().first();
assertThat(result).contains(channel);
}
After Change
@Test
public void pubsubChannels() throws Exception {
block(pubsub.subscribe(channel));
List<String> result = first(pubsub2.pubsubChannels().toList());
assertThat(result).contains(channel);
}